/*******************************************************************/
/* @ All Rights Reserved Copyright (C) 2014 broada,Co.,Ltd.        */
/*                                                                 */
/*  NAME      = fix_base_type.h                                    */
/*  NOTE      =                                                    */
/*  DATE      = 2015/10/23 by zhengxd                              */
/*******************************************************************/
#ifndef __FIX_BASE_TYPE_H_
#define __FIX_BASE_TYPE_H_

#include "frmem.h"
#include "frstr.h"
#include "frcomm.h"
#include "frlist.h"
#include "frhash2.h"
#include "frlog.h"
#include "iconv2utf8.h"
#include "frsutl.h"
#include "frhex_dump.h"

#include "conntrack.h"
#include "module.h"
#include "frct_comm.h"
#include "frdb_cursor.h"
#include "frreport_comm.h"
#include "frbyte_buffer.h"

#define KAFKA_REQ_TP_PRODUCE             0
#define KAFKA_REQ_TP_FETCH               1
#define KAFKA_REQ_TP_OFFSET              2
#define KAFKA_REQ_TP_METADATA            3
//#define KAFKA_REQ_TP_NON_USER     4-7
#define KAFKA_REQ_TP_OFFSET_COMMIT       8
#define KAFKA_REQ_TP_OFFSET_FETCH        9
#define KAFKA_REQ_TP_CONSUMER_METADATA   10
//0.7以及以下版本的request type
//#define KAFKA_REQ_TP_PRODUCE             0
//#define KAFKA_REQ_TP_FETCH               1
#define KAFKA_REQ_TP_MULTIFETCH          2
#define KAFKA_REQ_TP_MULTIPRODUCE        3
#define KAFKA_REQ_TP_OFFSETS             4

#define KAFKA_VERSION_6                  6
#define KAFKA_VERSION_7                  7
#define KAFKA_VERSION_8                  8

#endif
